val rdd = sc.parallelize(1 to 100)
val rdd2 = rdd.filter(_ > 50).map(_ * 2).filter(_ > 100)
println(rdd2.collect.mkString(", "))

